const mysql = require('mysql')
const { MYSQL_CONF } = require('../conf/db')

const con = mysql.createConnection(MYSQL_CONF) // 创建连接对象

con.connect() // 开始连接

const exec = (sql) => { // 统一执行函数
  const promise = new Promise((res, rej) => {
    con.query(sql, (err, result) => {
      if (err) {
        rej(err)
        return
      }
      res(result)
    })
  })
  return promise
}

module.exports = {
  exec
}